#include "app_mqtt.h"
#include  "log.h"
#include  "unistd.h"

//声明一个处理接收数据的方法
static int callback_func(char *str)
{
    log_info("hello ,%s" ,str);
    return 0;
}


int main(int argc, char const *argv[])
{
    // 1  初始mqtt
    app_mqtt_init();

    // 2  发送数据 
    app_mqtt_send("hello world!!");


    // 3  接收数据 
    // 把处理接收数据的方法注册给队列模块，一旦有数据接收，回调该函数
    app_mqtt_register_recv_callback(callback_func);

    sleep(10000);

    app_mqtt_destroy();
    return 0;
}